package com.ias.amq.consummer;

import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Component;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.TextMessage;

@Component
public class ConsummerDemo1 {

    @JmsListener(destination = "test-inner-MultiAmqQueue", containerFactory = "innerAmqMessageListener")
    public void receiveTestMultiMessage(Message msg) throws JMSException {
        System.out.println("接收到测试多数据源inner队列的消息"+((TextMessage) msg).getText());

    }
}
